package com.xuecheng.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.xuecheng.model.po.MqMessage;

import java.util.List;

public interface MqMessageService extends IService<MqMessage> {
	
	/**
	 * 扫描消息表记录，采用与扫描视频处理表相同的思路
	 */
	List<MqMessage> getMessageList(int shardIndex, int shardTotal, String messageType, int count);
	
	/**
	 * 添加消息
	 */
	MqMessage addMessage(String messageType, String businessKey1, String businessKey2, String businessKey3);
	
	/**
	 * 完成任务
	 */
	public int completed(long id);
	
	/**
	 * 完成阶段任务
	 */
	int completedStageOne(long id);
	
	int completedStageTwo(long id);
	
	int completedStageThree(long id);
	
	int completedStageFour(long id);
	
	/**
	 * 查询阶段状态
	 */
	int getStageOne(long id);
	
	int getStageTwo(long id);
	
	int getStageThree(long id);
	
	int getStageFour(long id);
	
}
